//package com.google.code.bigyang.util;
//
//import java.util.concurrent.LinkedBlockingQueue;
//import java.util.concurrent.atomic.AtomicInteger;
//
//import other.MyHandler;
//import other.NioSocketSession;
//
//import com.google.code.bigyang.base.Task;
//
//public class QueueThreadPool implements ThreadPool,Runnable {
//
//	private LinkedBlockingQueue<Task> queue = new LinkedBlockingQueue<Task>();
//	
//	private AtomicInteger index = new AtomicInteger(0);
//	
//	
//	public void run() {
//		while(true) {
//			try {
//				Task task = queue.take();
//				NioSocketSession session = task.getSession();
//				Thread t = new Thread(new MyHandler(session),"hanlder-"+index.incrementAndGet());
//				t.start();
//			} catch (InterruptedException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//	
//	
//	public void schedule(Task task) {
//		queue.add(task);
//	}
//	
//	
//}
